package com.galeno.练习

import com.alibaba.fastjson.JSON
import com.galeno.utils.SparkUtil
import org.apache.spark.rdd.RDD

/**
 * @Title: ${file_name}
 * @Description: ${todo}
 * @author galeno
 * @date 2021/8/2816:26
 */
object  事件归因{
  def main(args: Array[String]): Unit = {
    val sc = SparkUtil.getSc
    val rdd1: RDD[String] = sc.textFile("F:/applog/app_log_2021-06-08.log")

    rdd1.map(json=>{
      val jSONObject = JSON.parseObject(json)
      val account = JSON.parseObject("account")


    })






  }


}
